c1d70965f785d681ae8909271a56969bb2e044fa,vertx-web-client/src/test/java/io/vertx/ext/web/client/WebClientTest.java,WebClientTest,testResponseBodyStream,#,518

Before Change


      }
    };
    HttpRequest get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
    get.send(BodyCodec.pipe(stream), onSuccess(resp -> {
      assertTrue(ended.get());
      assertEquals(200, resp.statusCode());
      assertEquals(null, resp.body());

After Change


      }
    };
    HttpRequest<Buffer> get = client.get(DEFAULT_HTTP_PORT, DEFAULT_HTTP_HOST, "/somepath");
    get
      .as(BodyCodec.pipe(stream))
      .send(onSuccess(resp -> {
      assertTrue(ended.get());
      assertEquals(200, resp.statusCode());
      assertEquals(null, resp.body());